package com.doom.a3rdlibdemo;

public abstract class BasicFuseableObserver<T, R> implements Observer<T>{

    protected final Observer<T> actual;

    public BasicFuseableObserver(Observer<T> actual) {
        this.actual = actual;
    }

    @Override
    public void onSubscribe() {
        this.actual.onSubscribe();
    }

//    @Override
//    public void onNext(T t) {
//        this.actual.onNext(t);
//    }

    @Override
    public void onError(Throwable e) {
        this.actual.onError(e);
    }

    @Override
    public void onComplete() {
        this.actual.onComplete();
    }
}
